package com.im.server.enterprise.business.push;

import javax.annotation.Resource;

import org.springframework.stereotype.Service;

import com.im.server.general.business.mq.MessageQueueWriteHandler;
import com.onlyxiahui.im.message.Head;
import com.onlyxiahui.im.message.server.PushMessage;

/**
 * @author: XiaHui
 * @date: 2016年8月26日 上午9:21:41
 */
@Service
public class DepartmentPush {
	@Resource
	MessageQueueWriteHandler messageQueueWriteHandler;

	/**
	 * 推送刷新部门结构
	 * 
	 * @author: XiaHui
	 * @param key
	 * @param userIdList
	 * @createDate: 2017年8月17日 下午2:05:34
	 * @update: XiaHui
	 * @updateDate: 2017年8月17日 下午2:05:34
	 */
	public void pushDepartmentListUpdate(String key) {
		PushMessage message = new PushMessage();
		Head head = new Head();

		head.setAction("1.1100");
		head.setMethod("1.2.1001");
		head.setKey(key);
		head.setTime(System.currentTimeMillis());
		message.setHead(head);
		messageQueueWriteHandler.push(message);
	}

	/**
	 * 推送刷新部门信息
	 * 
	 * @author: XiaHui
	 * @param key
	 * @param departmentId
	 * @param userIdList
	 * @createDate: 2017年8月17日 下午2:05:53
	 * @update: XiaHui
	 * @updateDate: 2017年8月17日 下午2:05:53
	 */
	public void pushDepartmentUpdate(String key, String departmentId) {
		PushMessage message = new PushMessage();
		message.put("departmentId", departmentId);

		Head head = new Head();
		head.setAction("1.1100");
		head.setMethod("1.2.1002");
		head.setKey(key);
		head.setTime(System.currentTimeMillis());
		message.setHead(head);
		messageQueueWriteHandler.push(message);
	}

	/**
	 * 成员修改
	 * 
	 * @author: XiaHui
	 * @param key
	 * @createDate: 2017年8月17日 下午3:05:20
	 * @update: XiaHui
	 * @updateDate: 2017年8月17日 下午3:05:20
	 */
	public void pushDepartmentMemberListUpdate(String key) {
		PushMessage message = new PushMessage();
		Head head = new Head();

		head.setAction("1.1100");
		head.setMethod("1.2.1003");
		head.setKey(key);
		head.setTime(System.currentTimeMillis());
		message.setHead(head);
		messageQueueWriteHandler.push(message);
	}
}
